google.golang.org/grpc.addrConnStream.transportStream (field)
14 uses
google.golang.org/grpc (current package)
stream.go#L1326: as.transportStream = s
stream.go#L1353: transportStream *transport.ClientStream
stream.go#L1377: m, err := as.transportStream.Header()
stream.go#L1385: return as.transportStream.Trailer()
stream.go#L1395: as.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
stream.go#L1404: return as.transportStream.Context()
stream.go#L1445: if err := as.transportStream.Write(hdr, payload, &transport.WriteOptions{Last: !as.desc.ClientStreams}); err != nil {
stream.go#L1468: if ct := as.transportStream.RecvCompress(); ct != "" && ct != encoding.Identity {
stream.go#L1482: if err := recv(as.parser, as.codec, as.transportStream, as.decompressorV0, m, *as.callInfo.maxReceiveMessageSize, nil, as.decompressorV1, false); err != nil {
stream.go#L1484: if statusErr := as.transportStream.Status().Err(); statusErr != nil {
stream.go#L1499: if err := recv(as.parser, as.codec, as.transportStream, as.decompressorV0, m, *as.callInfo.maxReceiveMessageSize, nil, as.decompressorV1, false); err == io.EOF {
stream.go#L1500: return as.transportStream.Status().Err() // non-server streaming Recv returns nil on success
stream.go#L1518: if as.transportStream != nil {
stream.go#L1519: as.transportStream.Close(err)